/*
 * TCPListenerSubscriber.cpp
 *
 *  Created on: 06.04.2011
 *      Author: niea
 */

#include "TCPListenerSubscriber.hpp"

#include <iostream>

namespace efs
{

TCPListenerSubscriber::TCPListenerSubscriber()
{
	pthread_mutex_init(&m_mutex, NULL);
}


TCPListenerSubscriber::~TCPListenerSubscriber()
{
	pthread_mutex_destroy(&m_mutex);
}

void TCPListenerSubscriber::processTCPMessageLock(std::string const& message)
{
	Lock lock(&m_mutex);
	lock;
	//std::cout <<"msg = " << message << std::endl;
	processTCPMessage(message);
}

}
